//package com.kafka.service.observer;
//
//
//
///**
// * 观察者主题对象
// */
//public interface Observerable {
//    /**
//     * 订阅
//     * @param o
//     */
//    public void registerObserver(Observer o);
//
//    /**
//     * 移除
//     * @param o
//     */
//    public void removeObserver(Observer o);
//
//    /**
//     * 通知
//     */
//    public void notifyObserver();
//}
